package com.hub.realtime.flinkshims.core;

import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.descriptors.ConnectTableDescriptor;
import org.apache.flink.table.descriptors.ConnectorDescriptor;

public class TableContext extends FlinkTableBase{


    public TableContext(ParameterTool parameter, StreamExecutionEnvironment senv, TableEnvironment tableEnv) {
        super(parameter, senv,tableEnv);
    }


    @Deprecated
    @Override
    public ConnectTableDescriptor connect(ConnectorDescriptor connectorDescriptor) {
        return tableEnv.connect(connectorDescriptor);
    }
}
